package com.qf.ps;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 路由模式   ----  定向交换机  监听器
 * @author lixu
 */
@Component
public class DirectQueue {

    //Spring官方整合RabbitMQ
    /**
     *      <dependency>
     *             <groupId>org.springframework.boot</groupId>
     *             <artifactId>spring-boot-starter-amqp</artifactId>
     *         </dependency>
     */

    /**
     * 消费者1  消费队列1   direct_queue1
     */
    @RabbitListener(queues = "direct_queue1")
    public void receiverMessageDirectQueue1(String msg){
        // 方法形参 ;  可以直接接收任意类型的消息
        System.out.println("=====direct_queue1：消费者1：" + msg);
    }



    /**
     * 消费者2  消费队列2   direct_queue2
     */
    @RabbitListener(queues = "direct_queue2")
    public void receiverMessageDirectQueue2(String msg){//自动确认： 将队列将消息删除

        // 方法形参 ;  可以直接接收任意类型的消息
        System.out.println("=====direct_queue2：消费者2：" + msg);


        int i = 1/0;//抛出异常 了


        //.......... 代码 还未执行



        //使用手动确认  队列 你删除消费吧


    }
}
